//package bbkj.org.cn.sink;
//
//import org.apache.flink.streaming.api.functions.sink.RichSinkFunction;
//
//public class WriteSink<T> extends RichSinkFunction<T>{
//	/**
//	 * 
//	 */
//	private static final long serialVersionUID = -6438037347696105555L;
//
//	private SinkCallback<T> callback;
//	public WriteSink(SinkCallback<T> callback) {
//		this.callback = callback;
//	}
//
//	public void invoke(T value, Context context) throws Exception {
//		if(callback!=null) {
//			callback.callback(value);
//		}
//    }
//}
